package org.zbclan.bf2.rcon.service;

public interface MessageQueueService {

	Object CONNECTION_SYNC = new Object();

	void send(String queue, String message) throws MessageQueueException;

	/**
	 * non-blocking
	 * 
	 * @param queue
	 * @return
	 * @throws MessageQueueException
	 */
	String fetch(String queue) throws MessageQueueException;

	/**
	 * blocking
	 * 
	 * @param queue
	 * @return
	 * @throws MessageQueueException
	 */
	String receive(String queue) throws MessageQueueException;
}
